api/admin_views.py

@@ -9,9 +9,12 @@ from django_response import response

                 from paginator import pagination
              

                 from TimeConvert import TimeConvert as tc
              

                 from django.db.models import Sum
              

                +from datetime import datetime
              

                 
              

                -from mch.models import AdministratorInfo, ConsumeInfoSubmitLogInfo, SaleclerkInfo
              

                +from mch.models import AdministratorInfo, ConsumeInfoSubmitLogInfo, SaleclerkInfo, ModelInfo
              

                 from statistic.models import ConsumeModelSaleStatisticInfo, ConsumeSaleStatisticInfo, ConsumeUserStatisticInfo, ModelSaleStatisticInfo
              

                +from integral.models import SaleclerkSubmitLogInfo
              

                +from logs.models import MchInfoEncryptLogInfo
              

                 from account.models import UserInfo
              

                 from utils.error.errno_utils import (AdministratorStatusCode, ProductBrandStatusCode, ProductCouponStatusCode,
              

                                                      ProductMachineStatusCode, UserStatusCode)
              
@@ -356,3 +359,45 @@ def statistic_distributor(request):

                         'model_logs': model_logs,
              

                         'distributor_logs': distributor_logs
              

                     })
              

                +
              

                +def statistic_deep_analyze(request):
              

                +    start_time = request.POST.get('start_time', '')
              

                +    end_time = request.POST.get('end_time', '')
              

                +
              

                +    start_date = datetime.strptime(start_time + ' 00:00:00', '%Y-%m-%d %H:%M:%S')
              

                +    end_date = datetime.strptime(end_time + ' 23:59:59', '%Y-%m-%d %H:%M:%S')
              

                +    logs = ConsumeInfoSubmitLogInfo.objects.filter(created_at__range=(start_date, end_date), dupload=False, test_user=False)
              

                +    res = []
              

                +
              

                +    for log in logs:
              

                +        modelInfo = ModelInfo.objects.get(model_id=log.model_id)
              

                +        item = {'user_id': log.user_id, 'model_name': log.model_name, 'serialNo': log.serialNo}
              

                +        try:
              

                +            sale_log = SaleclerkSubmitLogInfo.objects.get(model_name=modelInfo.model_name, code=log.serialNo)
              

                +            item['distributor_name'] = sale_log.distributor_name
              

                +            item['outbound_time'] = sale_log.created_at
              

                +        except:
              

                +            item['distributor_name'] = ''
              

                +            item['outbound_time'] = ''
              

                +
              

                +        
              

                +        date = datetime.strptime('2020-01-14 00:00:00', '%Y-%m-%d %H:%M:%S')
              

                +        encryptLog = MchInfoEncryptLogInfo.objects.filter(created_at__gte=date, sn=log.serialNo, model_pk=modelInfo.pk)
              

                +        if not encryptLog:
              

                +            item['is_new_code'] = False
              

                +            item['is_complement'] = False
              

                +        elif encryptLog.all()[0].operator_id == 'ZCQebtBiQHT8XRKpmbUotD':
              

                +            item['is_complement'] = True
              

                +            item['is_new_code'] = False
              

                +        elif encryptLog.all()[0].operator_id == '5qX3KWXZ8iKaip4AdxwtKF':
              

                +            item['is_new_code'] = True    
              

                +            item['is_complement'] = False
              

                +
              

                +        if encryptLog:
              

                +            item['outbound_time'] = encryptLog.all()[0].created_at 
              

                +        else:
              

                +            item['outbound_time'] = ''
              

                +
              

                +        res.append(item)
              

                +
              

                +    return response(data=res)
              

api/urls.py

@@ -301,6 +301,9 @@ urlpatterns += [

                     url(r'^admin/statistic/consumer/model$', admin_views.statistic_model, name='statistic_model'),
              

                 
              

                     url(r'^admin/statistic/distributor$', admin_views.statistic_distributor, name='statistic_distributor'),
              

                +
              

                +    url(r'^admin/statistic/deep/analyze$', admin_views.statistic_deep_analyze, name='statistic_deep_analyze'),
              

                +
              

                 ]
              

                 
              

                 urlpatterns += [